package com.chb.dmp.etl

import org.apache.spark.sql.{Dataset, Row}

trait Processor {
  def process(ds: Dataset[Row]): Dataset[Row]
}
